package main

import (
	"beego_benchu/services/mq"
	"fmt"
)

func main() {
	// 接收 同一个topic下所有信息
	mq.ConsumerEx("fyouku.demo.topic", "topic", "#", callback)
}

func callback(s string) {
	fmt.Print("msg is : %s\n", s)
}
